package com.shujia.sql

import org.apache.flink.table.functions.ScalarFunction

/**
  * 自定义函数
  *
  */
class Demo13Split extends ScalarFunction {

  /**
    * flink 只识别eval这个方法名
    *
    * @param lines ： 函数的参数
    * @return
    */
  def eval(lines: String, sep: String): Array[String] = {
    lines.split(sep)
  }
}
